package com.leigq.www.producer.config;

import lombok.extern.slf4j.Slf4j;
import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * KafKa相关配置
 * <br/>
 * 参考：
 * <ul>
 *     <li><a href='https://www.cnblogs.com/lxw180/articles/14870898.html'>springboot-kafka实战</a></li>
 *     <li><a href='https://blog.csdn.net/liuxiao723846/article/details/120924617'>SpringBoot 整合 Spring Kafka，消息重试和死信队列的应用</a></li>
 * </ul>
 * <p>
 * <br/>
 * 纯注解方式实现，在消费端使用注解，即可自动创建队列及绑定关系
 * <br/>
 *
 * @author ：leigq
 * @date ：2019/7/25 20:14
 */
@Configuration
@Slf4j
public class KafkaConfig {

    /**
     * 程序启动时创建Topic
     *
     * @return the new topic
     */
    @Bean
    public NewTopic topic2() {
        return new NewTopic("topic-k2", 2, (short) 2);
    }

}
